package Test.MQ;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;

import javax.annotation.Resource;

/**
 * RabbitMq测试类
 * @author pan_junbiao
 **/
public class RabbitMqTest {
    @Resource
    RabbitTemplate rabbitTemplate;

    public void sendMessage() throws Exception{
        String message = "您好，欢迎访问 pan_junbiao的博客";

        //这里故意将routingKey参数写入错误，让其应发确认消息送到队列失败回调
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, "no_queue_name", message);

        //由于这里使用的是测试方法，当测试方法结束，RabbitMQ相关的资源也就关闭了，
        //会导致消息确认的回调出现问题，所有加段延时
        Thread.sleep(2000);
    }
}